package com.yh.config.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * @author yh
 */
@Component
@ConfigurationProperties(prefix = "spring.rocket-mq.consumer")
@Data
public class ConsumerProperties {

    private String groupName;

    private String serverAddress;

    private String topics;

    private Integer consumeThreadMin;

    private Integer consumeThreadMax;

    private Integer consumeMessageBatchMaxSize;

    private String subscribe;
}
